package com.kl.example.serializer;

import com.alibaba.fastjson.JSON;
import com.kl.example.model.MessageModelExample;
import org.apache.kafka.common.serialization.Serializer;

/**
 * 基于fastjson的序列化器
 */
public class MyMessageJsonSerializer implements Serializer<MessageModelExample> {

    /**
     * 直接使用第三方的序列化工具
     */
    @Override
    public byte[] serialize(String topic, MessageModelExample data) {
        return JSON.toJSONBytes(data);
    }
}
